package com.netsdk.socket;

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

public class DataStore {
	private final static BlockingDeque<String> deque = new LinkedBlockingDeque<>();


    public static void set(String str){
        deque.addLast(str);
    }

    public static String get() throws InterruptedException {
        return deque.take();
    }
}
